//package com.zhz.mall.portal.kakfa;
//
//import org.apache.kafka.clients.consumer.ConsumerRecord;
//
///**
// * KafkaMessageListener
// * <p>
// * kafka 消息监听器
// *
// * @author zhouhengzhe
// */
//public interface KafkaMessageListener {
//
//    /**
//     * 获取监听器名称
//     */
//    String getName();
//
//    /**
//     * 监听的主题
//     */
//    String getTopic();
//
//    /**
//     * 接收消息
//     */
//    void onMessage(ConsumerRecord record);
//
//}
